package lzzsrj.union.message.redis.listener;

import java.lang.annotation.*;

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface RedisMQListener {

    //队列名称
    String topic() default "";

    //拉取消息时间间隔(毫秒)
    long interval() default 1;

    //每次拉取多少条消息
    int quantity() default 1;

}
